package com.flink.demo.connector12;

import org.apache.flink.api.java.DataSet;
import org.apache.flink.api.java.ExecutionEnvironment;

/**
 * description
 *
 * @author zsyoung@qq.com
 * 2020/8/2 1:12
 */
public class ConnectorDemo {
    public static void main(String[] args) throws Exception {
        ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
        DataSet<Person> csvInput = env.readCsvFile("D:\\test.csv").pojoType(Person.class, "name", "age", "zipcode");

        csvInput.print();

    }

}
